package com.example.redissondemo.consumer;

import lombok.extern.slf4j.Slf4j;
import org.redisson.api.listener.MessageListener;
import org.springframework.stereotype.Component;

/**
 * RTopic订阅消息
 * @author Liunh
 */
@Slf4j
@Component
public class TestStringMessageListener implements MessageListener<String> {

    public static final String TOPIC_STRING_TEST = "RTopic_String_Msg_test";

    @Override
    public void onMessage(CharSequence channel, String msg) {
        log.info(">>>>>> 订阅到的消息:{}", msg);
    }
}
